﻿using Sustainalytics.Synchronization.Interface;
using System.Collections.Generic;
using Xunit;

namespace Sustainalytics.ClientDW.Synchronization.Tests
{
    public class CleanupS3SyncStepTests
    {
        private readonly string databaseKey = "ClientDW";
        private readonly string databaseGroup = "A";

        [Fact]
        public void CleanUpS3Buckets()
        {
            var database = string.Format("{0}_{1}", databaseKey, databaseGroup);

            S3CleanupSyncStep syncStep = new S3CleanupSyncStep();
            SyncContext syncContext = new SyncContext()
            {
                GAConnectionStrings = new Dictionary<string, string>(),
                Report = new System.Collections.Concurrent.ConcurrentBag<string>()
            };

            syncContext.GAConnectionStrings.Add(databaseKey, database);

            syncStep.Start(syncContext);
        }
    }
}
